﻿//========================================================= 
/**@file rocketmq_extractor.cpp
 * @brief RocketMq常用功能封装资源文件
 * 
 * @date 2018-08-31   15:01:21
 * @author Zhyioo 
 * @version 1.0
 */ 
//--------------------------------------------------------- 
#ifndef _LIBZHOUYB_ROCKETMQ_EXTRACTOR_CPP_
#define _LIBZHOUYB_ROCKETMQ_EXTRACTOR_CPP_
//--------------------------------------------------------- 
#include "rocketmq_extractor.h"
//--------------------------------------------------------- 
namespace zhou_yb {
namespace wrapper {
namespace rocketmq_extractor {
//--------------------------------------------------------- 
OrderlyMsgQueueSelecter RocketMqHelper::OrderlySelector;

ByteArray RocketMqHelper::LAST_OFFSET("CONSUME_FROM_LAST_OFFSET");
ByteArray RocketMqHelper::LAST_AND_BOOT_FIRST_OFFSET("CONSUME_FROM_LAST_OFFSET_AND_FROM_MIN_WHEN_BOOT_FIRST");
ByteArray RocketMqHelper::MIN_OFFSET("CONSUME_FROM_MIN_OFFSET");
ByteArray RocketMqHelper::MAX_OFFSET("CONSUME_FROM_MAX_OFFSET");
ByteArray RocketMqHelper::FIRST_OFFSET("CONSUME_FROM_FIRST_OFFSET");
ByteArray RocketMqHelper::TIMESTAMP("CONSUME_FROM_TIMESTAMP");

size_t RocketMqHelper::COMSUMER_FROM_TABLE_SIZE = 6;
ByteArray RocketMqHelper::COMSUMER_FROM_TABLE[6] = { 
    LAST_OFFSET, 
    LAST_AND_BOOT_FIRST_OFFSET, 
    MIN_OFFSET, 
    MAX_OFFSET, 
    FIRST_OFFSET, 
    TIMESTAMP
};
//--------------------------------------------------------- 
} // namespace rocketmq_extractor 
} // namespace wrapper
} // namespace zhou_yb 
//--------------------------------------------------------- 
#endif // _LIBZHOUYB_ROCKETMQ_EXTRACTOR_CPP_
//========================================================= 